Flink Window那些事——AggregateFunction窗口函數

AggregateFunction 比 ReduceFunction 更加的通用，它有三個參數:輸入類型(IN)、累加器類型(ACC)和輸出類型(OUT)。 輸入類型是輸入流中的元素類型，Aggre ...

Flink Window那些事——窗口函數

Window Function在窗口觸發后，負責對窗口內的元素進行計算。Window Function分為兩類: 增量聚合和全量聚合。 增量聚合: 窗口不維護原始數據，只維護中間結果，每次基於中 ...